Skip to content

[flink] Skip updates to non-projected columns - #5115

Open
loserwang1024 wants to merge 2 commits into
apache:mainfrom
loserwang1024:fluss-project-read
Open

loserwang1024 wants to merge 2 commits into
apache:mainfrom
loserwang1024:fluss-project-read

Conversation

@loserwang1024

Copy link
Copy Markdown
Contributor

Purpose

Linked issue: close #3095

Brief change log

Tests

API and Format

Documentation

@loserwang1024

Copy link
Copy Markdown
Contributor Author

@leonardBang , would you like to help review this pr.

Pass the scan's primary-key flag through the source readers so virtual
tables retain every change event even when their backing table has a
primary key. Preserve filtering for ordinary projected primary-key scans.

Add a bounded changelog regression combining projected data and metadata
columns with filtering enabled and disabled, and extend split-reader
coverage for scans without a primary key.

Validation: reproduced the regression before the fix; 30 targeted tests
passed on Flink 1.20 with Spotless and Checkstyle checks passing.

Co-Authored-By: Codex <noreply@openai.com>
AI-Model: gpt-6
AI-Contributed/Feature: 10/10
AI-Contributed/UT: 71/71
@loserwang1024

Copy link
Copy Markdown
Contributor Author

@leonardBang , I have modified it.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

[flink] Skip emitting update events when only non-projected columns are modified in source connector

2 participants